package com.shang.web.reactor8;

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

/**
 * @ClassName TestReactor
 * @Description TODO
 * @Author Larry
 * @Date 2021/5/25 20:39
 * @Version 1.0
 */

public class TestReactor {
    public static void main(String[] args) {
        Flux.just(1,2,3,4).subscribe(System.out::print);
        Mono.just(1).subscribe(System.out::print);
    }
}
